# from sqlalchemy.ext.asyncio import AsyncSession
# from module_admin.entity.vo.common_vo import CrudResponseModel
# from modules.base.sys.notice.dao import SysNoticeDao
# from modules.base.sys.notice.model import SysNotice
# from utils.common_util import CamelCaseUtil
#
#
# class SysNoticeService:
#     """
#     通知公告管理模块服务层
#     """
#
#     # @classmethod
#     # async def get_notice_list_services(
#     #     cls, query_db: AsyncSession, query_object: NoticePageQueryModel, is_page: bool = True
#     # ):
#     #     """
#     #     获取通知公告列表信息service
#     #
#     #     :param query_db: orm对象
#     #     :param query_object: 查询参数对象
#     #     :param is_page: 是否开启分页
#     #     :return: 通知公告列表信息对象
#     #     """
#     #     notice_list_result = await NoticeDao.get_notice_list(query_db, query_object, is_page)
#     #
#     #     return notice_list_result
#
#     # @classmethod
#     # async def check_notice_unique_services(cls, query_db: AsyncSession, page_object: NoticeModel):
#     #     """
#     #     校验通知公告是否存在service
#     #
#     #     :param query_db: orm对象
#     #     :param page_object: 通知公告对象
#     #     :return: 校验结果
#     #     """
#     #     notice_id = -1 if page_object.notice_id is None else page_object.notice_id
#     #     notice = await NoticeDao.get_notice_detail_by_info(query_db, page_object)
#     #     if notice and notice.notice_id != notice_id:
#     #         return CommonConstant.NOT_UNIQUE
#     #     return CommonConstant.UNIQUE
#
#     @classmethod
#     async def insert(cls, query_db: AsyncSession, page_object: SysNotice):
#         """
#         新增通知公告信息service
#
#         :param query_db: orm对象
#         :param page_object: 新增通知公告对象
#         :return: 新增通知公告校验结果
#         """
#         try:
#             await SysNoticeDao.insert(query_db, page_object)
#             # await query_db.commit()
#             return CrudResponseModel(is_success=True, message='新增成功')
#         except Exception as e:
#             # await query_db.rollback()
#             raise e
#
#     # @classmethod
#     # async def edit_notice_services(cls, query_db: AsyncSession, page_object: NoticeModel):
#     #     """
#     #     编辑通知公告信息service
#     #
#     #     :param query_db: orm对象
#     #     :param page_object: 编辑通知公告对象
#     #     :return: 编辑通知公告校验结果
#     #     """
#     #     edit_notice = page_object.model_dump(exclude_unset=True)
#     #     notice_info = await cls.notice_detail_services(query_db, page_object.notice_id)
#     #     if notice_info.notice_id:
#     #         if not await cls.check_notice_unique_services(query_db, page_object):
#     #             raise ServiceException(message=f'修改通知公告{page_object.notice_title}失败，通知公告已存在')
#     #         else:
#     #             try:
#     #                 await NoticeDao.edit_notice_dao(query_db, edit_notice)
#     #                 await query_db.commit()
#     #                 return CrudResponseModel(is_success=True, message='更新成功')
#     #             except Exception as e:
#     #                 await query_db.rollback()
#     #                 raise e
#     #     else:
#     #         raise ServiceException(message='通知公告不存在')
#
#     # @classmethod
#     # async def delete_notice_services(cls, query_db: AsyncSession, page_object: DeleteNoticeModel):
#     #     """
#     #     删除通知公告信息service
#     #
#     #     :param query_db: orm对象
#     #     :param page_object: 删除通知公告对象
#     #     :return: 删除通知公告校验结果
#     #     """
#     #     if page_object.notice_ids:
#     #         notice_id_list = page_object.notice_ids.split(',')
#     #         try:
#     #             for notice_id in notice_id_list:
#     #                 await SysOrgDeptDao.delete(query_db, NoticeModel(noticeId=notice_id))
#     #             await query_db.commit()
#     #             return CrudResponseModel(is_success=True, message='删除成功')
#     #         except Exception as e:
#     #             await query_db.rollback()
#     #             raise e
#     #     else:
#     #         raise ServiceException(message='传入通知公告id为空')
#
#     # @classmethod
#     # async def notice_detail_services(cls, query_db: AsyncSession, notice_id: int):
#     #     """
#     #     获取通知公告详细信息service
#     #
#     #     :param query_db: orm对象
#     #     :param notice_id: 通知公告id
#     #     :return: 通知公告id对应的信息
#     #     """
#     #     notice = await NoticeDao.get_notice_detail_by_id(query_db, notice_id=notice_id)
#     #     if notice:
#     #         result = NoticeModel(**CamelCaseUtil.transform_result(notice))
#     #     else:
#     #         result = NoticeModel(**dict())
#     #
#     #     return result
